package com.example.rxbyhand;

/**
 * Author by lp,on 2021/8/16/016,16:46.
 * 观察者顶层接口
 */
public interface Observer<T> {
    void onSubscribe();

    void onNext(T t);

    void onComplete();

    void onError(Throwable throwable);
}
